import pika
import sys

# 创建连接对象，配置账号密码和地址
parameters = pika.URLParameters('amqp://root:123qwe@118.89.175.35:5672/%2F')
connection = pika.BlockingConnection(parameters)
# 获取连接通道
channel = connection.channel()
# 在连接成功之后，我们声明了一个交换器
# 这一个是很重要的，因为不允许发布消息到不存在的交换器。
# 如果没有绑定队列到交换器，消息将会丢失。
# 但这个没有所谓，如果没有消费者监听，那么消息就会被忽略。
channel.exchange_declare(exchange='logs', exchange_type='fanout')

message = ' '.join(sys.argv[1:]) or "info: Hello World!"
channel.basic_publish(exchange='logs', routing_key='', body=message)
print(" [x] Sent %r" % message)
connection.close()
